package com.xinqing.bigdata.test.datastream

import org.apache.flink.api.common.functions.FilterFunction

/**
  * @Author:CHQ
  * @Date:2020 /6/22 15:32
  * @Description
  */
class MyFilter extends FilterFunction[SensorReading] {
  override def filter(t: SensorReading): Boolean = {
    t.id.startsWith("sensor_1")
  }
}
